package cn.ygyg.bps.bus.starter.client;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @desc：BpsBusClient
 * @author: guanliang.xue
 * @date: 2021/5/11 17:56
 * @version:
 * @since:
 */
public interface BpsBusClient {

    /**
     * Name of the input channel for Spring Cloud Bus.
     */
    String INPUT = "orderInput";

    /**
     * Name of the output channel for Spring Cloud Bus.
     */
    String OUTPUT = "orderOutput";

    /**
     * Output
     * @return
     */
    @Output(BpsBusClient.OUTPUT)
    MessageChannel orderOutput();

    /**
     * Input
     * @return
     */
    @Input(BpsBusClient.INPUT)
    SubscribableChannel orderInput();
}
